package processor

import (
	"context"
	"ocan_data_sync_task/models"
)

// Processor 定义处理器接口
type Processor interface {
	GetType() models.TaskType           //  返回处理器支持的任务类型
	ValidateRequest(*models.Task) error // 验证任务请求参数
	// Process 处理单个任务项
	// ctx: 上下文
	// item: 待处理的数据项
	// commonParams: 公共参数
	Process(ctx context.Context,
		item map[string]interface{},
		commonParams map[string]interface{}) models.ItemTaskResult
}
